package com.apes.framework.plugin.mq;

import com.apes.framework.plugin.mq.rocketmq.autoconfigure.RocketMQMessageListener;

public interface Consumer {

    String getTopic();

    boolean isBackup();

    int getPeriod();

    boolean consume(MQEvent ropEvent);

    boolean isTransaction();

    RocketMQMessageListener getRocketMQMessageListener();

    void setRocketMQMessageListener(RocketMQMessageListener rocketMQMessageListener);

}
